package cn.tedu.m5;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Scanner;

/**
 * 主题模式
 */
@Component
public class Producter {
    //发送消息的封装工具
    @Autowired
    private AmqpTemplate t;

    //自定义的方法，需要自己手动调用
    public void send(){
        while (true){
        System.out.println("请输入消息：");
        String s = new Scanner(System.in).nextLine();
        System.out.println("请输入路由键：");
        String k = new Scanner(System.in).nextLine();
        //转换并发送，先转成byte[]数组再发送
        t.convertAndSend("topic_logs", k,s);
        }
    }
}
